package net.wicp.tams.common.flink.source.binlog;

import org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext;

import lombok.Data;
import net.wicp.tams.common.binlog.alone.normalize.IBinlogListener;
import net.wicp.tams.duckula.client.Protobuf3.DuckulaEvent;

@Data
public class FlinkBinlogListener implements IBinlogListener {
	
	private SourceContext<DuckulaEvent> ctx;
	
	@Override
	public void doBui(DuckulaEvent duckulaEvent) {
		ctx.collect(duckulaEvent);		
	}

	@Override
	public void init() {
		
	}

	@Override
	public void close() {
		
	}
}
